feat(queue/sql): add subscriber with partition leasing#23
Merged
Conversation
This was referenced Feb 17, 2026
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
8618be1 to
5925535
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
b29f000 to
8d4d338
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
5925535 to
e1143ed
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
8d4d338 to
7ef5cb2
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
e1143ed to
160fc71
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
7ef5cb2 to
07c58fe
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
160fc71 to
c6708be
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
07c58fe to
9de4a23
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
c6708be to
6b9a01f
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
9de4a23 to
8c32db0
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
6b9a01f to
74d181d
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
2 times, most recently
from
010ac2e to
d0f0ae6
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
2 times, most recently
from
c0eea0f to
2577b76
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
d0f0ae6 to
37a2f33
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
2577b76 to
1386759
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
37a2f33 to
4a17f4e
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
2 times, most recently
from
3a8459a to
c19e90d
Compare
sbalabanov
requested changes
Feb 19, 2026
behinddwalls
force-pushed
the
sql-queue-publisher
branch
3 times, most recently
from
20d554f to
ed4c674
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
4a17f4e to
dc9f4cc
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
ed4c674 to
d3915a7
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
dc9f4cc to
aca4bfe
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
2 times, most recently
from
642429b to
331f173
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
aca4bfe to
fcccb0c
Compare
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
331f173 to
d7597af
Compare
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
fcccb0c to
9ea80b3
Compare
sbalabanov
approved these changes
Feb 20, 2026
behinddwalls
force-pushed
the
sql-queue-publisher
branch
from
d7597af to
0dde36e
Compare
behinddwalls
added a commit
that referenced
this pull request
Feb 20, 2026
## Summary ### Why? Need Publisher implementation to enable message publishing to SQL queue topics. ### What? - Publisher validates topic names and publishes single messages via MessageStore - Thread-safe with RWMutex for concurrent publish calls - Idempotent Close() operation - Comprehensive test coverage for publish, validation, metrics, and concurrency - Single and multiple message publishing tested - Invalid topic names rejected (uppercase, special chars, empty) - Publisher closed state prevents further publishes - Concurrent publish operations verified thread-safe - Context cancellation handled correctly ## Test Plan make test ## Issues ## Stack 1. @ #22 1. #23 1. #21 1. #24 1. #34
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
9ea80b3 to
752bb37
Compare
…cking - Implement Subscriber interface with partition-based message polling - Add partition lease management for distributed workers - Add offset tracking per partition for consumption progress - Extend MessageStore interface with FetchByOffset, SetVisibilityTimeout, MoveToDLQ - Add OffsetStore interface for offset management - Add PartitionLeaseStore interface for partition leasing - Generate mocks for all three store interfaces - Add standardized metric tags (topic + partition_key) across all operations - Add comprehensive test coverage for subscription, ack/nack, and error handling
behinddwalls
force-pushed
the
sql-queue-subscriber
branch
from
752bb37 to
bc7b5bb
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Why?
Need Subscriber implementation with partition leasing to enable distributed message processing from SQL queue.
What?
Test Plan
bazel test